package inutan.robot.broker;

import org.ricks.common.lang.Logger;
import org.ricks.net.AioSession;
import org.ricks.net.handler.HeartPlugin;

/**
 * 心跳超时回调
 */
public class HeartTimeoutCallback implements HeartPlugin.TimeoutCallback {

    @Override
    public void callback(AioSession session, long lastTime) {
        Logger.info("心跳超时" + session + " & " + session.isInvalid() + " , start close session");
        session.close(true);
    }
}
